package com.fly.easy.queue.croe;

import com.fly.easy.queue.common.MessageEntity;

public interface FlyMessageHandle {
	
	/**
	 * 消费处理
	 * @param entity
	 */
	public void proccess(MessageEntity entity) ;

}
